package com.课上案例练习.网络编程.Tcp编程聊天版本3.接收的线程;

import java.io.DataInputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class CilentThreadinput extends Thread {
    /**
     * 为什么要在这里定义一个变量
     * 目的是接收传输过来的，连接的输入流
     * 保证在同一个连接上获取输入流
     */
    private Socket socket;

    public CilentThreadinput(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        //死循环的目的是不断的接收传输过来的信息
        while(true){
            try {
                DataInputStream dataInputStream = new DataInputStream(socket.getInputStream());
                System.out.println(dataInputStream.readUTF());
            } catch (IOException e) {
                throw new RuntimeException(e);
            }
        }
    }
}
